package com.wyt.engine;

import org.apache.kylin.cube.CubeSegment;
import org.apache.kylin.engine.mr.MRBatchCubingEngine2;
import org.apache.kylin.job.execution.DefaultChainedExecutable;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * @ClassName KylinEngine
 * @Description: TODO
 * @Author wangyongtao
 * @Date 2021/8/22 20:19
 * @Version 1.0
 **/
public class KylinEngine extends MRBatchCubingEngine2 {
    private static Logger logger = LoggerFactory.getLogger(KylinEngine.class);
    @Override
    public DefaultChainedExecutable createBatchCubingJob(CubeSegment newSegment, String submitter, Integer priorityOffset) {
        logger.info("wyt01kylinplus: this is KylinEngine!");
        return super.createBatchCubingJob(newSegment, submitter, priorityOffset);
    }
}